這段關係就讓 Lambda 繼續默默付出吧

• 按照前置作業，我們已經把 RSS Feed 的內容結構化成 JSON 格式，並儲存成 feed.json 放在 S3 bucket 中
• 可以按照 day22 前一支 image resizer 的 lambda 一樣，建立步驟一致，只是需要限定在不同的 prefix 位置

該怎麼做

• 繼續假設大家都是 Gopher，可以使用我醜醜醜的 code 作為 lambda

package main

import (
	"bytes"
	"context"
	"encoding/json"
	"fmt"
	"strings"

	"github.com/aws/aws-lambda-go/events"
	"github.com/aws/aws-lambda-go/lambda"
	"github.com/aws/aws-sdk-go/aws"
	"github.com/aws/aws-sdk-go/aws/session"
	"github.com/aws/aws-sdk-go/service/s3"
)

// Feed represents feed.json structure
type Feed struct {
	Podcast struct {
		LastBuildDate string `json:"lastBuildDate"`
		Title         string `json:"title"`
		Description   string `json:"description"`
		Image         struct {
			URL   string `json:"url"`
			Title string `json:"title"`
			Link  string `json:"link"`
		} `json:"image"`
		Link         string `json:"link"`
		Author       string `json:"author"`
		Copyright    string `json:"copyright"`
		Email        string `json:"email"`
		Language     string `json:"language"`
		Type         string `json:"type"`
		CategoryMain string `json:"category_main"`
		CategorySub  string `json:"category_sub"`
		Explicit     string `json:"explicit"`
		Episodes     []struct {
			Title       string `json:"title"`
			Description string `json:"description"`
			Link        string `json:"link"`
			Audio       string `json:"audio"`
			Creator     string `json:"creator"`
			Explicit    string `json:"explicit"`
			Duration    string `json:"duration"`
			Image       string `json:"image"`
			Episode     int    `json:"episode"`
			Type        string `json:"type"`
		} `json:"episodes"`
	} `json:"podcast"`
}

// GOOS=linux GOARCH=arm64 CGO_ENABLED=0 go build -o bootstrap -tags lambda.norpc main.go
// zip myFunction.zip bootstrap
func main() {
	lambda.Start(handler)
}

func handler(ctx context.Context, s3Event events.S3Event) error {
	sess := session.Must(session.NewSession())
	svc := s3.New(sess)
	object := s3Event.Records[0].S3.Object
	bucket := "intoxicating"
	key := object.Key

	// Download object from S3
	resp, err := svc.GetObject(&s3.GetObjectInput{
		Bucket: aws.String(bucket),
		Key:    aws.String(key),
	})
	if err != nil {
		fmt.Println("Error while downloading the object", err)
		return err
	}

	defer resp.Body.Close()

	// Decode JSON payload into struct
	var feed Feed
	json.NewDecoder(resp.Body).Decode(&feed)

	// Generate RSS feed based on feed.json
	fmt.Println(feed)
	rssFeed := generateRSS(feed)
	fmt.Println("RSS feed input:")

	// Upload RSS feed to S3 root path as feed.rss
	var body bytes.Buffer
	body.Write(rssFeed)
	fmt.Println("RSS feed output:")
	fmt.Println(string(rssFeed))
	uploadResp, err := svc.PutObject(&s3.PutObjectInput{
		Body:        bytes.NewReader(body.Bytes()),
		Bucket:      aws.String(bucket),
		Key:         aws.String("feed.rss"),
		ContentType: aws.String("application/xml"),
	})
	if err != nil {
		fmt.Println("Error while uploading the object", err)
		return err
	}

	fmt.Printf("Feed uploaded to S3 with status %v\n", uploadResp)

	return nil
}

• 經過一樣的 build 與 zip ，上傳後就可以測試啦，不只需要測試 Lambda 是否可以執行，也要用 day24 的 RSS validator 確認一下是否符合規範喔

 GOOS=linux GOARCH=arm64 CGO_ENABLED=0 go build -o bootstrap -tags lambda.norpc main.go

zip myFunction.zip bootstrap

其他延伸

• 到這邊為止，最最簡單基礎的 Hugo 網站＋ Podcast host 功能就基本完成了，可以回顧一下目前的成果
• 發現成果有限，但是，最重要的是開始，要開始上傳第一集喔
• 發現這支 lambda 其實還未完成，還漏了一個重要的 function，但約好了要吃薑母鴨，明天再來測試...
• 發現明天開始上班...

外出取材番外

• 還是繼續分享一些有趣的東東，例如在蘇格蘭的廁所標誌